9ee7d016072f45060d14af3e5e6ddd75a92285f6,distributedlog-core/src/test/java/com/twitter/distributedlog/TestBKLogReadHandler.java,TestBKLogReadHandler,testGetLogRecordCountWithSingleInProgressLedger,#,353
Before Change
Await.result(out.write(DLMTestUtil.getLargeLogRecordInstance(txid++, false)));
BKLogReadHandler readHandler = bkdlm.createReadHandler();
List<LogSegmentMetadata> ledgerList = readHandler.getLedgerList(false, false, LogSegmentMetadata.COMPARATOR, false);
assertEquals(1, ledgerList.size());
assertTrue(ledgerList.get(0).isInProgress());
After Change
Await.result(out.write(DLMTestUtil.getLargeLogRecordInstance(txid++, false)));
BKLogReadHandler readHandler = bkdlm.createReadHandler();
List<LogSegmentMetadata> ledgerList = FutureUtils.result(
readHandler.readLogSegmentsFromStore(
LogSegmentMetadata.COMPARATOR,
LogSegmentFilter.DEFAULT_FILTER,
null
)
).getValue();
assertEquals(1, ledgerList.size());
assertTrue(ledgerList.get(0).isInProgress());